public void block() {
blockReceived = true;
flushStartReceived.countDown();
}
}
}
public void block() {
blockReceived=true;
if(flushStartReceived != null)
flushStartReceived.countDown();
events.add(new BlockEvent());
}